CSharpTCP编程,客户端服务器通信

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Net;using System.Net.Sockets;using System.IO;using System.Threading;namespace TCPServer{ public partial class frmSyncTcpServer : Form { #region 变量 // 申明变量 private TcpListener tcpLister = null; private TcpClient tcpClient = null; //给定网络服务器地址 IPAddress ipaddress=IPAddress.Parse("192.168.2.123"); //给定串口号 private const int Port = 8087; private NetworkStream networkStream = null; private BinaryReader TCPreader; private BinaryWriter TCPwriter; // 申明委托 // 显示消息 private delegate void ShowMessage(string str); private ShowMessage showMessageCallback; // 显示状态 private delegate void ShowStatus(string str); private ShowStatus showStatusCallBack; // 清空消息 private delegate void ResetMessage(); private ResetMessage resetMessageCallBack; #endregion public frmSyncTcpServer() { InitializeComponent(); #region 实例化委托 // 显示消息 showMessageCallback = new ShowMessage(showMessage); // 显示状态 showStatusCallBack = new ShowStatus(showStatus); // 重置消息 resetMessageCallBack = new ResetMessage(resetMessage); #endregion //在页面默认显示的IP地址 //ipaddress = IPAddress.Loopback;"192.168.2.104"; tbxserverIp.Text = ipaddress.ToString(); tbxPort.Text = Port.ToString(); } #region 定义回调函数 // 显示消息 private void showMessage(string str) { lstbxMessageView.Items.Add(tcpClient.Client.RemoteEndPoint); lstbxMessageView.Items.Add(str); lstbxMessageView.TopIndex = lstbxMessageView.Items.Count - 1; } // 显示状态 private void showStatus(string str) { toolStripStatusInfo.Text = str; } // 清空消息 private void resetMessage() { tbxMessage.Text = string.Empty; tbxMessage.Focus(); } #endregion #region Click事件 // 开始监听 private void btnStart_Click(object sender, EventArgs e) { //连接服务器IP，端口 //tcpLister = new TcpListener(ipaddress, Port); tcpLister = new TcpListener(IPAddress.Parse("192.168.2.123"),8087); //线程启动 tcpLister.Start(); // 启动一个线程来接受请求 Thread acceptThread =new Thread(acceptClientConnect); acceptThread.Start(); } // 线程里面的动作---接受请求 private void acceptClientConnect() { statusStripInfo.Invoke(showStatusCallBack,"正在监听"); Thread.Sleep(500); try { statusStripInfo.Invoke(showStatusCallBack,"等待连接"); tcpClient = tcpLister.AcceptTcpClient(); //有监听的客户端 if (tcpLister!= null) { statusStripInfo.Invoke(showStatusCallBack,"接受到连接"); networkStream = tcpClient.GetStream(); TCPreader = new BinaryReader(networkStream); TCPwriter = new BinaryWriter(networkStream); try { string receivemessage = TCPreader.ReadString(); //list显示接收到的信息 lstbxMessageView.Invoke(showMessageCallback, receivemessage); } catch { if (TCPreader != null) { TCPreader.Close(); } if (TCPwriter != null) { TCPwriter.Close(); } if (tcpClient != null) { tcpClient.Close(); } } } } catch { statusStripInfo.Invoke(showStatusCallBack, "停止监听"); Thread.Sleep(500); //没有接收到客户端时候的状态 statusStripInfo.Invoke(showStatusCallBack, "就绪"); } } // 关闭监听 private void btnStop_Click(object sender, EventArgs e) { tcpLister.Stop(); } // 清空消息 private void btnClear_Click(object sender, EventArgs e) { lstbxMessageView.Items.Clear(); } // 接受消息 private void btnReceive_Click(object sender, EventArgs e) { statusStripInfo.Invoke(showStatusCallBack, "接受消息中"); try { string receivemessage = TCPreader.ReadString(); //list显示接收到的信息 lstbxMessageView.Invoke(showMessageCallback, receivemessage); } catch { if (TCPreader != null) { TCPreader.Close(); } if (TCPwriter != null) { TCPwriter.Close(); } if (tcpClient != null) { tcpClient.Close(); } statusStripInfo.Invoke(showStatusCallBack, "断开了连接"); // 重新开启一个线程等待新的连接 Thread acceptThread = new Thread(acceptClientConnect); acceptThread.Start(); } } // 发送消息 private void btnSend_Click(object sender, EventArgs e) { Thread sendThread = new Thread(SendMessage); sendThread.Start(tbxMessage.Text); } // 发送消息 private void SendMessage(object state) { statusStripInfo.Invoke(showStatusCallBack, "正在发送"); try { TCPwriter.Write(state.ToString()); Thread.Sleep(2000); TCPwriter.Flush(); statusStripInfo.Invoke(showStatusCallBack, "完毕"); tbxMessage.Invoke(resetMessageCallBack, null); lstbxMessageView.Invoke(showMessageCallback, state.ToString()); } catch { if (TCPreader != null) { TCPreader.Close(); } if (TCPwriter != null) { TCPwriter.Close(); } if (tcpClient != null) { tcpClient.Close(); } statusStripInfo.Invoke(showStatusCallBack, "断开了连接"); // 重新开启一个线程等待新的连接 Thread acceptThread = new Thread(acceptClientConnect); acceptThread.Start(); } } private void button1_Click(object sender, EventArgs e) { if (TCPreader != null) { TCPreader.Close(); } if (TCPwriter != null) { TCPwriter.Close(); } if (tcpClient != null) { // 断开连接 tcpClient.Close(); } toolStripStatusInfo.Text = "断开连接"; // 启动一个线程等待接受新的请求 Thread acceptThread = new Thread(acceptClientConnect); acceptThread.Start(); } #endregion private void tbxMessage_TextChanged(object sender, EventArgs e) { } private void frmSyncTcpServer_Load(object sender, EventArgs e) { } }}